package sampleexec;

import org.apache.flink.annotation.PublicEvolving;
import org.apache.flink.streaming.api.functions.sink.SinkFunction;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

@PublicEvolving
public class SimepleEntitySink implements SinkFunction<SimpleEntity> {
    private static final long serialVersionUID = 1L;
    private static final Logger LOG = LoggerFactory.getLogger(SimepleEntitySink.class);

    public SimepleEntitySink() {
    }

    public void invoke(SimpleEntity value, Context context) {
        System.out.println("sink data -> " + value);
    }
}
